package com.atguigu0.core

import org.apache.spark.Partitioner

/**
 * @description: xxx
 * @time: 2020/6/13 20:09
 * @author: baojinlong
 **/
class CustomerPartitioner(inputPartitionsNum: Int) extends Partitioner {
  override def numPartitions: Int = inputPartitionsNum

  override def getPartition(key: Any): Int = {
    0
  }
}
